#include "parametersqldb.h"

ParameterSQLDB::ParameterSQLDB(QObject *parent) : QObject(parent) {}

bool ParameterSQLDB::execSql(const QString &sql)
{
    if (!m_db || !m_db->isOpen()) return false;
    QMutexLocker locker(&m_mutex);
    QSqlQuery query(*m_db);
    if (!query.exec(sql)) {
        qDebug() << "SQL执行失败：" << query.lastError().text() << " | SQL:" << sql;
        return false;
    }
    return true;
}

QSqlQuery *ParameterSQLDB::execSqlResult(const QString &sql)
{
    if (!m_db || !m_db->isOpen()) return nullptr;
    QMutexLocker locker(&m_mutex);
    QSqlQuery *query = new QSqlQuery(*m_db);
    if (!query->exec(sql)) {
        qDebug() << "SQL查询失败：" << query->lastError().text() << " | SQL:" << sql;
        delete query;
        return nullptr;
    }
    return query;
}
